package thread;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingDeque;
import java.util.concurrent.BlockingQueue;

public class ThreadDemo3 {
    public static void main(String[] args) throws InterruptedException {
        BlockingQueue<String> queue = new ArrayBlockingQueue<String>(100);
        //使用put和offer都是入队列
        //但是put是带有阻塞功能的,offer如果满了会返回一个boolean类型的结果(false)
        queue.put("aaa");
        //take方法用来出队列,也带有阻塞功能
        String elem = queue.take();
        System.out.println(elem);
        elem = queue.take();//此时阻塞
        System.out.println(elem);//没有打印结果
        //阻塞队列没有提供带有阻塞功能的获取队首元素的方法

    }
}
